category: sub_main
step: 2_staging
sub_step: 1_join
in_main_macro: join
doc_status: readymacro join_sheets_periodstat
| Name | Category | In Sub-Main Macro | Doc Status |
|---|---|---|---|
| get_relations_by_re | auxiliary | join_appmetrica_events, join_appmetrica_registry_appprofilematching, join_appsflyer_events, join_mt_datestat, join_sheets_periodstat, join_vkads_datestat, join_utmcraft_registry_utmhashregistry, join_yd_datestat, join_yd_datestat_smart, join_ym_events | ready |
Этот подвид макроса join предназначен для работы с данными источника sheets, которые относятся к пайплайну periodstat.
Этот макрос принимает следующие аргументы:
sourcetype_name,
pipeline_name,
relations_dict,
date_from,
date_to,
params,
limit0=none
Макрос обрабатывает данные стрима planCosts из источника sheets. Предполагается, что такие данные относятся к пайплайну periodstat.
Для вышеуказанного стрима макрос ищет relations при помощи вспомогательного макроса get_relations_by_re, затем создаёт таблицу-источник при помощи вспомогательного макроса dbt_utils.union_relations. (Этот макрос из пакета dbt_utils, он не относится к datacraft).
Далее полученные данные макрос обрабатывает (происходит переименование полей, для некоторых столбцов вводится LowCardinality).
Для этой таблицы задаётся её линк (это будет использоваться на будущих шагах):
toLowCardinality('ManualAdCostStat') AS __linkЕсли аргумент limit0 активирован, то в конце SQL-запроса будет добавлено LIMIT 0.
Файл в формате sql в папке models. Название файла join_sheets_periodstat
Содержимое файла:
-- depends_on: {{ ref('incremental_sheets_periodstat_default_planCosts') }}
{{ datacraft.join() }}